package com.huaming.kafka.kafka;

import java.io.Serializable;
import java.util.Map;

/**
 * Created by tima-test on 2016/11/18.
 */
public class MessageKafka implements Serializable{
    String topic;
    String key;
    String content;
    Map<String,String> extendInfo;

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public Map<String, String> getExtendInfo() {
        return extendInfo;
    }

    public void setExtendInfo(Map<String, String> extendInfo) {
        this.extendInfo = extendInfo;
    }
}
